package com.qf.helloworld;

import com.qf.util.MQConnUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import org.junit.Test;

/**
 *  openapi-admin
 *  添加用户信息到数据库成功
 *  发消息到MQ中
 *
 */
public class Publisher {

    public static final String HELLO_WORLD_QUEUE = "helloWorldQueue";

    @Test
    public void publish() throws Exception {
//        - 获取Connection
        Connection conn = MQConnUtil.getConn();
//        - 创建Channel
        Channel channel = conn.createChannel();
//        - 创建Exchange（无需创建,默认交换机名称为""）
//        - 发送消息到Exchange，并设置消息的RoutingKey
        String msg = "Hello RabbitMQ!";
        /*
        1. exchange：指定使用的交换机名称，默认的交换机叫空串
        2. routingKey：默认的交换机类型，要求RoutingKey必须和队列名称一致
        3. props：设置消息携带的其他信息……
        4. body：具体的消息
         */
        channel.basicPublish("",HELLO_WORLD_QUEUE,null,msg.getBytes());
//        - 释放资源
        channel.close();
        conn.close();
    }


}
